package com.wdl.networkflow.pv

import org.apache.flink.api.common.functions.MapFunction

import scala.util.Random

class PvCountMap() extends MapFunction[UserBehavior, (String, Long)] {
  override def map(value: UserBehavior): (String, Long) = {
    (Random.nextInt(4).toString, 1L)
  }
}
